package main.java.com.waylau.netty.demo.echo;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

/**
 * 处理服务端 channel.
 */
public class EchoServerHandler extends ChannelInboundHandlerAdapter {

    /**
     * @param ctx
     * @param msg
     *
     */
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
//      通过Telnet 进行测试：将每次发送过来的数据 返回
    	System.out.println(ctx.channel().remoteAddress()+"-> Client :"+ msg.toString());
        ctx.write(msg); // (1) 发送消息
        ctx.flush(); // (2) 发送
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { 
        // 当出现异常就关闭连接
        cause.printStackTrace();
        ctx.close();
    }
}